8396ee3654c3a7b58091798b566f889df972f7a2,src/test/java/io/pivotal/literx/Part06OtherOperations.java,Part06OtherOperations,fluxWithValueInsteadOfError,#,139
Before Change
TestSubscriber
.subscribe(flux)
.assertValues(User.SKYLER, User.WALTER)
.assertComplete();
}
// TODO Return a Flux<User> containing Saul and Jesse when an error occurs in the input Flux, else do not change the input Flux.
After Change
flux = betterCallSaulAndJesseForBogusFlux(Flux.just(User.SKYLER, User.WALTER));
ScriptedSubscriber.create()
.expectValues(User.SKYLER, User.WALTER)
.expectComplete()
.verify(flux);
}
// TODO Return a Flux<User> containing Saul and Jesse when an error occurs in the input Flux, else do not change the input Flux.